package com.enjoyor.soa.traffic.frame.support.kafka.message;

import java.io.Serializable;

public class KafkaMessage implements Serializable, Cloneable {

    /**
     * 
     */
    private static final long serialVersionUID = 1582562416357355085L;

    /**
     * 统一消息头
     */
    protected KafkaMessageHeader messageHeader;

    /**
     * JSON格式消息体
     */
    private String jsonString;

    public KafkaMessage(KafkaMessageHeader messageHeader, String jsonString) {
        this.messageHeader = messageHeader;
        this.jsonString = jsonString;
    }

    public KafkaMessageHeader getMessageHeader() {
        return messageHeader;
    }

    public void setMessageHeader(KafkaMessageHeader messageHeader) {
        this.messageHeader = messageHeader;
    }

    public String getJsonString() {
        return jsonString;
    }

    public void setJsonString(String jsonString) {
        this.jsonString = jsonString;
    }

}
